package com.ada.spark.action

import org.apache.spark.{SparkConf, SparkContext}

/**
  * 作用：折叠操作，aggregate的简化操作，seqop和combop一样。
  */
object Demo8_fold {
    def main(args: Array[String]): Unit = {
        //创建SparkConf
        val conf = new SparkConf().setAppName("Demo8_fold").setMaster("local[*]")
        //创建Spark上下文对象
        val sc = new SparkContext(conf)

        var rdd = sc.makeRDD(1 to 10, 2)

        //折叠操作，aggregate的简化操作，seqop和combop一样。
        val result: Int = rdd.fold(0)(_ + _)

        println(result)
        //55
    }
}
